package com.alibaba.datax.plugin.reader.aliyunslsreader.test;

import com.aliyun.openservices.loghub.client.interfaces.ILogHubProcessor;
import com.aliyun.openservices.loghub.client.interfaces.ILogHubProcessorFactory;

public class SampleLogHubProcessorFactory implements ILogHubProcessorFactory {

    private String value;
    public void initValue(String value) {
        this.value = value;
    }

    public ILogHubProcessor generatorProcessor() {
        // 生成一个消费实例。
        SampleLogHubProcessor sampleLogHubProcessor = new SampleLogHubProcessor();
        sampleLogHubProcessor.initValue(this.value);
        return sampleLogHubProcessor;
    }
}
